c22e9098934d2fdf4205aae1e0f54eedc68bac33,jdbc-lib/src/test/java/com/streamsets/pipeline/stage/origin/jdbc/table/BasicIT.java,BasicIT,testChangeInOffsetColumnNameInConfig,#,558
Before Change
@Test
public void testChangeInOffsetColumnNameInConfig() throws Exception {
String offset = "";
String tableName = "TRANSACTION_TABLE";
offset = testChangeInOffsetColumns(
tableName,
offset,
ImmutableList.of("UNIQUE_INT"),
false
);
//Now we changed one column from offset configuration, should fail
testChangeInOffsetColumns(
After Change
@Test
public void testChangeInOffsetColumnNameInConfig() throws Exception {
Map<String, String> offset = new HashMap<>();
String tableName = "TRANSACTION_TABLE";
testChangeInOffsetColumns(
tableName,
offset,
ImmutableList.of("UNIQUE_INT"),
false
);
//Now we changed one column from offset configuration, should fail
testChangeInOffsetColumns(